//package net.dopan.pigframe.demo.controller;
//
//import net.dopan.pigframe.demo.socket.HelloSender1;
//import net.dopan.pigframe.demo.socket.HelloSender2;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//@RestController
//@RequestMapping("/rabbit")
//public class RabbitTest {
//
//    @Autowired
//    private HelloSender1 helloSender1;
//    @Autowired
//    private HelloSender2 helloSender2;
//
//
//    @GetMapping("/hello")
//    public String hello() {
//        helloSender1.send("a");
//        return "/rabbit/hello的调用";
//    }
//
//
//    /**
//     * 单生产者-多消费者
//     */
//    @GetMapping("/oneToMany")
//    public void oneToMany() {
//            helloSender1.send("hellomsg:");
//
//    }
//
//
//    /**
//     * 多生产者-多消费者
//     */
//    @GetMapping("/manyToMany")
//    public void manyToMany() {
//        for(int i=0;i<10;i++){
//            helloSender1.send("hellomsg:"+i);
//            helloSender2.send("hellomsg:"+i);
//        }
//
//    }
//}
